package com.yykj.tencent.im.server.tdmq;

import com.yykj.tencent.im.server.tdmq.producer.ListMessageTemplate;
import com.yykj.tencent.im.server.tdmq.producer.MessageTemplate;
import com.yykj.tencent.im.server.tdmq.producer.ObjectMessageTemplate;
import com.yykj.tencent.im.server.tdmq.producer.StringMessageTemplate;
import lombok.extern.slf4j.Slf4j;
import org.apache.pulsar.client.api.MessageId;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.List;

@Service
@Slf4j
public class TdmqService {

    @Resource
    StringMessageTemplate stringMessageTemplate;

    @Resource
    ListMessageTemplate listMessageTemplate;

    // 发送除集合以外的对象消息
    @Resource
    ObjectMessageTemplate objectMessageTemplate;

    // 发送任意消息
    @Resource
    MessageTemplate messageTemplate;

    /**
     * 发送字符串
     */
    public MessageId sendMessage(String message) {
        return null;
    }

    /**
     * 发送对象
     * @param obj 对象
     * @return
     */
    public MessageId sendMessage(Object obj) {
        return null;
    }

    /**
     * 发送对象集合
     * @param messages 对象集合
     * @return
     */
    public MessageId sendMessage(List<Object> messages) {
        return null;
    }



}
